const fs = require('fs')
const path = require('path');
const rs = fs.createReadStream(path.resolve(__dirname,'a.txt'),{
    highWaterMark:4 // 64k
})
const ws = new WriteStream(path.resolve(__dirname,'b.txt'),{
    highWaterMark:1 // 16k
})
// pipe 可以实现 从 a->b  效果是读一点写一点 是异步的
rs.pipe(ws);

// 读流 （on('data')  on('end')） -》 写流 (ws.write  ws.end) 



// rs.on('data',function(chunk){
//     let flag = ws.write(chunk)
//     if(!flag){
//         rs.pause()
//     }
// })
// ws.on('drain',function(){
//     rs.resume()
// })